package com.zyg.rm.test;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * ------------------------------
 * 作者: LMY
 * 类-功能: XX
 * 创建时间: 2021-11-08 19:48
 * ------------------------------
 **/
@RunWith(SpringRunner.class)
@SpringBootTest
public class JmsProducer {

    //引入RabbitMQ API
    @Autowired
    private RabbitTemplate rabbitTemplate;

    //1. 直连方式
    @Test
    public void test01(){
        //1.1 直接发送消息
        rabbitTemplate.convertAndSend("zelin","这里使用direct模式发送消息！");
    }


    //2. 订阅发布方式 交换机需要提前绑定队列，不需要路由Key
    @Test
    public void test02(){
        //1.1 直接发送消息
        rabbitTemplate.convertAndSend("zl-school","","fanout");
    }

    //3. 主题模式，需要绑定队列，也需要绑定路由Key
    @Test
    public void test03(){
        //1.1 直接发送消息
        rabbitTemplate.convertAndSend("zl-books","goods.log","这里是topic");
    }

    //3. 主题模式，需要绑定队列，也需要绑定路由Key
    @Test
    public void test04(){
        //1.1 直接发送消息
        rabbitTemplate.convertAndSend("zl-books","aa.log","这里是topic");
    }

    //3. 主题模式，需要绑定队列，也需要绑定路由Key
    @Test
    public void test05(){
        //1.1 直接发送消息
        rabbitTemplate.convertAndSend("zl-books","goods.aa","这里是topic");
    }







}
